/**
 * %%
 * %%
 */
package org.apache.flink.runtime.allocatedeploy.execution;

import java.io.Serializable;

import org.apache.flink.api.common.ConsumerID;
import org.apache.flink.runtime.clusterframework.types.AllocationID;

/**
 * @类名: CommandDescriptor
 * @说明: 下发命令描述
 *
 * @author   leehom
 * @Date	 2024年7月31日 下午6:15:39
 * 修改记录：
 *
 * @see 	 
 */
public class CommandDescriptor implements Serializable {

	private static final long serialVersionUID = 5007840305341522946L;
	
	/** 消费者*/
	private final ConsumerID consumerId;
	/** */
	private String command;
	/** 序列化的参数*/
	private String serArgs;
    /** The ID referencing the attempt to execute the task. */
    private final ExecutionID executionId;

    /** The allocation ID of the slot in which the task shall be run. */
    private final AllocationID allocationId;

	public CommandDescriptor(ConsumerID consumerId, 
			String command, String serArgs, ExecutionID executionId, AllocationID allocationId) {
		this.consumerId = consumerId;
		this.command = command;
		this.serArgs = serArgs;
		this.executionId = executionId;
		this.allocationId = allocationId;
	}

	public ConsumerID getConsumerId() {
		return consumerId;
	}

	public String getCommand() {
		return command;
	}

	public String getSerArgs() {
		return serArgs;
	}

	public ExecutionID getExecutionId() {
		return executionId;
	}

	public AllocationID getAllocationId() {
		return allocationId;
	}

}
